    package com.ruozedata.flume.rpc;


    import org.apache.log4j.Logger;

    public class RPCClientApp {

        private static Logger logger = Logger.getLogger(RPCClientApp.class);

        public static void main(String[] args) throws InterruptedException {
            int index = 0;

            while (true) {
                Thread.sleep(1000);
                logger.info("当前输出值：" + index++);
            }
        }
    }
